package com.ywu.mq.sdk.config;

import lombok.Data;
import lombok.ToString;

/**
 * @ClassName YwuKafkaSdkConfig
 * @Description TODO
 * @Author GroundDemo
 * @Date 2025/3/28 9:48
 * @Version 1.0
 **/
@ToString
@Data
public class YwuKafkaSdkConfig {
    private String bootstrapService;

    private String keySerializer = "org.apache.kafka.common.serialization.StringSerializer";

    private String valueSerializer = "org.apache.kafka.common.serialization.StringSerializer";

    private String keyDeserializer = "org.apache.kafka.common.serialization.StringDeserializer";

    private String valueDeserializer = "org.apache.kafka.common.serialization.StringDeserializer";

    private String offsetReset = "latest";

    private String tenantId;

    private String groupId;

    private String topicName;

    private Integer consumerNum;

    private String appId;

    private String appKey;

    private String topicAppId;
}
